package com.leigq.www.producer.service;

import com.leigq.www.producer.entity.BrokerMessageLog;
import com.leigq.www.producer.mapper.BrokerMessageLogMapper;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.List;

/**
 * Kafka消息记录
 */
@Service
@Transactional
public class BrokerMessageLogService {

    @Resource
    private BrokerMessageLogMapper messageLogMapper;

    /**
     * 修改
     * <br>创建人： asus
     * <br>创建时间： 2019-02-18 15:56
     * <br>
     * @param log BrokerMessageLog
     * @return 影响行数
     */
    public Integer update(BrokerMessageLog log) {
        return messageLogMapper.update(log);
    }


    /**
     * 插入
     * <br>创建人： asus
     * <br>创建时间： 2019-02-18 18:05
     * <br>
     * @param log BrokerMessageLog
     * @return 影响行数
     */
    public Integer insert(BrokerMessageLog log) {
        return messageLogMapper.insert(log);
    }

    /**
     * 查询过期(超时)消息进行重投，状态为确认中 并且 下次重试时间 <= 当前时间
     * <br>创建人： asus
     * <br>创建时间： 2019-02-18 21:11
     * <br>
     */
    public List<BrokerMessageLog> findOvertimeMsg() {
        return messageLogMapper.findOvertimeMsg();
    }
}
